package belf.migrate.plugin.mysql;

import belf.migrate.api.common.DatabaseIdentifier;
import belf.migrate.api.taskconf.JobContext;
import belf.migrate.api.source.cdc.CDCSource;
import belf.migrate.api.table.schema.CatalogTable;

import java.util.List;

public class MySQLCDCSource extends CDCSource {
    public MySQLCDCSource(JobContext jobContext) {
        super(jobContext);
    }

    @Override
    public String getPluginName() {
        return DatabaseIdentifier.MYSQL;
    }

    @Override
    public List<CatalogTable> getProducedCatalogTables() {
        return super.getProducedCatalogTables();
    }
}
